package com.spring_mysql_redis.utils;

import com.spring_mysql_redis.entity.Message;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class MsgSenderFanout {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    /**
     * 在自己的方法中调用这个类下的这个方法，根据自己不同的需求
     * 接收消息，并将消息传到mq交换机上，绑定了该交换机的队列的消费者都可收到该消息
     * @param message
     */
    public void send(String message) {
        System.out.println("Sender : " + message);
        rabbitTemplate.convertAndSend("myfanoutExchange","", message);

    }

}
